package storm.trident.fluent;

import storm.trident.Stream;
import storm.trident.operation.Aggregator;
import storm.trident.operation.Function;
import backtype.storm.tuple.Fields;


public interface IAggregatableStream {
    IAggregatableStream each(Fields inputFields, Function function, Fields functionFields);


    IAggregatableStream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields);


    Stream toStream();


    Fields getOutputFields();
}
